package org.dub.consumer.service;

import org.apache.dubbo.common.stream.StreamObserver;
import org.apache.dubbo.config.annotation.DubboReference;
import org.dub.api.service.UserStreamService;
import org.springframework.stereotype.Service;

/**
 * Created By bobin on 2024/7/28
 */
@Service
public class UserStreamServiceImpl implements UserStreamService {
    @DubboReference
    private UserStreamService userStreamService;

    @Override
    public StreamObserver<String> sayHello(StreamObserver<String> replyObserver) {
        return userStreamService.sayHello(replyObserver);
    }
}
